package cn.getech.data.development.entity;

import cn.getech.data.development.dto.JobNodeLayConfigDto;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import lombok.experimental.Accessors;

import java.io.Serializable;
import java.util.Date;
import java.util.List;

/**
 * <p>
 * 任务节点信息表
 * </p>
 *
 * @author zenith
 * @since 2019-07-08
 */
@Data
@Accessors(chain = true)
@TableName("bdp_job_node_info")
public class JobNodeInfo implements Serializable {

    private static final long serialVersionUID=1L;
    /**
     * 任务节点编号
     */
    @TableId(value = "id", type = IdType.AUTO)
    private Integer id;

    /***
     * 新的id，用于版本导入使用
     */
    @TableField(exist = false)
    private Integer newId;

    /**
     * 任务节点名称
     */
    @TableField("name")
    private String name;

    @TableField("`desc`")
    private String desc;

    /**
     * 任务节点类型 1 数据接入 2 SQL计算 3 程序执行 4 数据推送  6:shell脚本
     */
    @TableField("type_id")
    private Integer typeId;

    /**
     * 任务节点状态
     */
    @TableField("enable")
    private Boolean enable;

    /**
     * 创建时间
     */
    @TableField("create_time")
    private Date createTime;

    /**
     * 创建用户
     */
    @TableField("create_per")
    private Integer createPer;

    /**
     * 修改时间
     */
    @TableField("mod_time")
    private Date modTime;

    /**
     * 修改用户
     */
    @TableField("mod_per")
    private Integer modPer;

    /**
     * 上次运行状态 0 失败 1 成功 2 运行中
     */
    @TableField("last_run_state")
    private Integer lastRunState;

    /**
     * 上次运行时间
     */
    @TableField("last_run_time")
    private Date lastRunTime;

    /**
     * 上次运行耗时 单位ms
     */
    @TableField("last_run_cost")
    private Long lastRunCost;

    /**
     * 上次构建的编号
     */
    @TableField("last_run_num")
    private Integer lastRunNum;

    /**
     * 所属任务编号
     */
    @TableField("job_id")
    private Integer jobId;


    /**
     * 是否配置空跑 0：不空跑（正常）、1：空跑
     */
    @TableField("is_null_run")
    private Integer isNullRun;


    /**
     * 所属任务编号
     */
    @TableField(exist = false)
    private Integer newJobId;

    /**
     * 节点唯一键
     */
    @TableField("node_key")
    private String nodeKey;
    /**
     * 上一级节点
     */
    @TableField("`pnode_key`")
    private String pNodeKey;

    /**
     *节点的配置参数
     */
    @TableField(exist=false)
    private JobNodeConfig jobNodeConfig;

    /**
     * x的位置
     */
    @TableField("pos_x")
    private Double posX;

    /**
     * y的位置
     */
    @TableField("pos_y")
    private Double posY;

    /**
     * 是否是虚拟的任务节点  1：是虚拟的节点  0：正常的节点
     */
    @TableField("is_vir_copy")
    private Integer isVirCopy;

    /**
     * 过期时间  超过24个小时就删除
     */
    @TableField("is_vir_copy_expire")
    private Long isVirCopyExpire;


    /**
     * 工程id
     */
    @TableField(exist=false)
    private Integer procId;

    /**
     * 责任人
     */
    @TableField(exist=false)
    private String createPerName;

    /**
     * 依赖配置
     */
    @TableField(exist=false)
    private List<JobNodeLayConfigDto> jobNodeLayConfigDtoList;

    /**
     * 是否导入  1：是导入的（权限不一样）
     */
    @TableField(exist=false)
    private Integer isImport;

    //shell脚本才需要
    /**
     * 服务器地址
     */
    @TableField(exist=false)
    private String hostUrl;
    /**
     * 端口
     */
    @TableField(exist=false)
    private Integer port;


    /**
     * 用户名
     */
    @TableField(exist=false)
    private String username;

    /**
     * 密码
     */
    @TableField(exist=false)
    private String password;


    /**
     * 超时时间 0：未配置  时间间隔 单位分钟
     */
    @TableField(exist=false)
    private String outHours;

    /**
     * 是否配置超时
     */
    @TableField(exist=false)
    private String isOpenOutHours;


}
